const net = require('net');
const tp = require('../tcppk');

const client = net.createConnection({ port: 9808 }, () => {

    // 实例化消息类
    const TP = new tp();

    // socket 队列
    const sockets = new Map();

    // 获取服务端消息
    TP.get(client, sockets, (data) => {
        console.log(data);
        // 接受一个json
        console.log(JSON.parse(data.toString()))
    });

    // 写入一个整包
    const sql = TP.encodeMsg("str");
    client.write(sql);

    // 写出两个整包
    //client.write(Buffer.concat([sql, sql], sql.length+sql.length));

    // 写出半个包在来半个包
    // const hd = Buffer.allocUnsafe(4);
    // hd.writeInt32LE(Buffer("str").length);
    // client.write(hd);

    // setTimeout(() => {
    //     client.write(Buffer("str"));
    // },4000)

    // 写一个半包在写半包
    // const hd = Buffer.allocUnsafe(4);
    // hd.writeInt32LE(Buffer("str").length);
    // client.write(Buffer.concat([sql, hd], sql.length+hd.length));

    // setTimeout(() => {
    //     client.write(Buffer("str"));
    // },4000)

});